package com.xbongbong.pro.rabbitmq.binders;

import com.xbongbong.pro.rabbitmq.constant.OrderCenterBinderConstant;
import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;
import org.springframework.stereotype.Service;

@Service("orderCenterConsumerBinder")
public interface OrderCenterConsumerBinder {

    @Input(OrderCenterBinderConstant.ORDER_INPUT)
    SubscribableChannel orderInput();

    @Input(OrderCenterBinderConstant.DISTRIBUTOR_REFUND_INPUT)
    SubscribableChannel distributorRefundInput();
}
